//package cn.gemframe.kafka;
//
//import org.springframework.cloud.stream.annotation.Output;
//import org.springframework.messaging.MessageChannel;
//
//public interface AcceptLogsWrite {
//
//	String OUTPUT = "logsWrite";
//
//	@Output(AcceptLogsWrite.OUTPUT)
//	MessageChannel output1();
//}
